package com.doit.spark.day07

import org.apache.spark.{SparkConf, SparkContext}

/**
 * @DATE 2022/1/10/20:33
 * @Author MDK
 * @Version 2021.2.2
 * */
object Demo01_Serializable {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("demo").setMaster("local[*]")
      .set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
      .registerKryoClasses(Array(classOf[User]))

    val sc = new SparkContext(conf)

  }
}
